package com.liustar.mq.rocketmq;

import org.apache.rocketmq.common.message.Message;

/**
 * 消费者监听接口，业务需要实现此接口并配置到Consumer中。
 *
 * @author Leo
 */
public interface MessageListener {

    /**
     * 具体业务实现方法
     *
     * @param message
     * @return
     */
    boolean onMessage(Message message);
}

